package com.hjh.thread.condition.condition2;

import java.util.concurrent.TimeUnit;

public class ProducerRunnable implements Runnable {

    public ProducerRunnable(){

    }


    @Override
    public void run() {

        long index = 0;
        while (true){
            QueueManager.getInstance().add("produce"+index);

            index++;
            if(index == Long.MAX_VALUE){
                index =0;
            }
        }

    }
}
